// 启动一个websocket服务
// import { WebSocketServer } from 'ws';
const  {WebSocketServer} = require('ws');
// 创建服务
const wss = new WebSocketServer({ port: 8080 });
// 监听客户端连接事件
wss.on('connection', function connection(ws) {
  console.log('客户端连接了');
  /*
    ws.send() 向客户端发消息
    ws.close() 关闭连接
    ws.on() 监听事件
       message事件 监听客户端 发送消息
       error 监听错误
       close 监听关闭
  */ 
  ws.on('error', console.error);

  ws.on('message', function message(data) {
    // console.log('received: %s', data);

    // 服务端回应消息
    const sendMsg = data.toString().replace(/你/gi, "我");
    ws.send(sendMsg.substr(0, sendMsg.length-1));
  });

  // ws.send('something');
});